const mysql = require('mysql');
//登录Sql
var con = mysql.createConnection({
    host: 'localhost',
    port: 3306,
    user: 'root',
    password: 'nozomi520',
    database: 'test1'
});

con.connect((err) => {
    if (err) {
        console.log(err);
    } else {
        console.log('数据库连接成功');
    }
});

//sql函数
function sqlQuery(strSql){
    return new Promise(function(reslove,reject){
        con.query(strSql, function (error, results, fields) {
            if(error){
                reject(error);
            }else{
                let dataString = JSON.stringify(results);
                let list = JSON.parse(dataString);
                reslove(list);
            }
        }); 
    }) 
}

//test↓
// let strSql1 = `
//         select *
//         from user
//         where uname = '吞吞'
//     `
// async function sqlSelect(strSql){
//     let result = await sqlQuery(strSql);
//     console.log('result:',result);
//     return result;
// }

module.exports = sqlQuery;